import pika

"""
消费者也是一样的，我们这里也是可以通过 input 方法控制何时取用下一个，获取的方法就是 basic_get ，返回一个元组，其中 body 就是真正的数据。

运行消费者，回车几下，就可以看到每次回车都可以看到从消息队列中获取了一个新的数据：
这样我们就可以实现消费者的随用随取了。
"""

QUEUE_NAME = 'scrape'
connection = pika.BlockingConnection(
    pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

while True:
    input()
    method_frame, header, body = channel.basic_get(
        queue=QUEUE_NAME, auto_ack=True)
    if body:
        print(f'Get {body}')